package cn.gcjxsc.messaging.sink;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface OrderShippedSink {
    /**
     * 订单发货通知
     */
    String QUE_NAME = "shopping_order_shipped_input";
    /**
     * 在线支付完成
     */
    String PAID_QUEUE = "shopping_order_paid_input";

    @Input(QUE_NAME)
    SubscribableChannel input();

    @Input(PAID_QUEUE)
    SubscribableChannel paidInput();
}
